package org.example.mq.common;

import org.example.mq.mqserver.core.BasicProperties;

import java.io.IOException;

/*
* 回调函数（函数式接口），收到消息之后要处理消息调用的方法
* */
public interface Consumer {
    /*
    * 推送消息给消费者
    * */
    void handleDelivery(String consumerTag, BasicProperties basicProperties,byte[] body) throws MqException, IOException;
}
